package com.muchfish.reactor.api;

import reactor.core.publisher.Flux;

public class ReactorIgnoreElementsExample {
    public static void main(String[] args) {
        Flux<Integer> source = Flux.just(1, 2, 3);

        // 忽略所有元素，只关注完成信号
        source.ignoreElements()
                .doOnTerminate(() -> System.out.println("Completed"))
                .subscribe();
    }
}
